8497f13baa0467eada1b806d7c7ac522a023d255,iep-rxhttp/src/test/java/com/netflix/iep/http/RxHttpTest.java,RxHttpTest,simplePost,#,536

Before Change


            return res.getContent();
          }
        })
        .toBlocking()
        .forEach(new Action1<ByteBuf>() {
          @Override
          public void call(ByteBuf byteBuf) {
            builder.append(byteBuf.toString(Charset.defaultCharset()));
          }
        });

    Assert.assertEquals("foo bar", builder.toString());

After Change


          Assert.assertEquals(200, res.getStatus().code());
          return res.getContent();
        })
        .toBlocking()
        .forEach(byteBuf -> builder.append(byteBuf.toString(Charset.defaultCharset())));

    Assert.assertEquals("foo bar", builder.toString());